package com.knight.hadoop.day04.mq.queue;

import java.util.Random;

public class ProductTest {
	public static void main(String[] args) throws Exception {
		ProductTool tool = new ProductTool();
		
		Random random = new Random();
		
		for(int i=0;i<20;i++){
			Thread.sleep(random.nextInt(6)*1000);
			tool.produceMessage("Hello,World!---"+i);
			tool.close();
		}
	}
}
